package com.xian.scala

import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.api.scala._

object MyTest {
  def main(args: Array[String]): Unit = {
    println("hi, scala-flink !")

    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment

    val ds: DataSet[Long] = env.fromElements(1L, 2L, 3L, 4L)

    ds.map(n => n*2)

  }

}
